package com.mp.ipm2020.admin.sevice;


import com.mp.ipm2020.admin.config.MqttConfig;
import org.springframework.integration.annotation.MessagingGateway;
import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.handler.annotation.Header;

/**
 * @Auther adidasshe@mp.cn
 *
 * 定义MQTT发送快捷方法
 */
@MessagingGateway(defaultRequestChannel = MqttConfig.CHANNEL_NAME_OUT)
public interface MqttSendSevice {

    /**
     * 发送信息到MQTT服务器
     */
    void sendToMqtt(String data);

    /**
     * 发送信息到MQTT服务器
     */
    void sendToMqtt(@Header(MqttHeaders.TOPIC) String topic,
                    String payload);

    /**
     * 发送信息到MQTT服务器
     */
    void sendToMqtt(@Header(MqttHeaders.TOPIC) String topic,
                    @Header(MqttHeaders.QOS) int qos,
                    String payload);
}
